package cn.zwx.common.rocket.consumer.listener;


import cn.zwx.common.rocket.consumer.bo.ConsumerListenerBO;

import java.util.function.Function;

/**
 *  消息消费回调，接收json格式消息，
 * 返回RetCode.code 000000 表示消费成功 其余为失败
 * 在超过最大失败次数前会重复投递该消息
 * @author Administrator
 */
public interface ConsumerListener extends Function<ConsumerListenerBO, String> {
}
